/*
 * 数据库连接模块
 */

const mysql = require('mysql2/promise');
const dotenv = require('dotenv');
dotenv.config();

const pool = mysql.createPool({
    host: process.env.MYSQLDB_HOST,
    user: process.env.MYSQLDB_USER,
    password: process.env.MYSQLDB_PASSWORD,
    database: process.env.MYSQLDB_NAME,
});

exports.query = async (sql, params) => {
    /*
    * execute()方法支持参数化查询，可以使用占位符（例如?）来代替查询中的参数，
    * 而query()方法不支持参数化查询，需要通过字符串拼接来传递参数
    */
    try{
        const [results] = await pool.execute(sql, params);
        return results;
    }
    catch(e){
        console.log('======query error======', e.message)
    }

    return null;
};
